package inutan.common.inner.protocol;

import org.ricks.net.AioSession;
import org.ricks.net.protocol.FixedLengthBytesProtocol;
import org.ricks.protocol.ByteBuf;
import org.ricks.protocol.ProtocolManager;


/**
 * @author chenwei
 * @Description: client <->  broker 字节流解析
 * 内部通信 tcp
 * @date 2023/2/1318:14
 */
public class InnerProtocol extends FixedLengthBytesProtocol {

    @Override
    protected Object decode(byte[] bytes, AioSession session) {
        return ProtocolManager.read(new ByteBuf(bytes));
    }
}
